package com.audaque.springboot.foshanupload.kafka.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author zgb
 * @desc 指定好kafka的topic之后，调用send方法会自动帮我们创建好topic，只是创建的topic默认是1个副本和1个分区的，数量可以在kafka的server.properties修改，也可以在客户端注册主题bean
 *
 * @date 2023-04-10 15:50:21
 */
@Configuration
public class KafkaTopicConfiguration {



/*

    // 创建一个名为 testTopic 的 topic 并设置分区数为 8，分区副本数为 2
    @Bean
    public NewTopic initialTopic() {
        return new NewTopic("testTopic", 2, (short) 2);
    }

    // 如果要修改分区数，只需修改配置值重启项目即可
    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
    @Bean
    public NewTopic updateTopic() {
        return new NewTopic("testTopic", 4, (short) 2);
    }
*/



    //创建TopicName为testTopic8的Topic并设置分区数为8以及副本数为1
    @Bean
    public NewTopic initialTopic() {
        return new NewTopic("testTopic8",8, (short) 1 );
    }





}
